#ifndef __QUEUE_READER__
#define __QUEUE_READER__

extern int next   (int index, queue_header *header, void **value);

extern int forward(int index);

extern int next_forward(int index, queue_header *header, void **value);

extern void rqueue_start();

extern void rqueue_stop ();

extern int  rqueue_open(int index);

extern int  rqueue_close(int index);

extern void main_rqueue(void* i);

#endif
